package com.swak.reactivex.transport;

import java.util.concurrent.CompletionStage;

import com.swak.exception.RemotingException;

public class ExchangeHandlerAdapter extends ChannelHandlerAdapter implements ExchangeHandler {

	@Override
	public CompletionStage<Object> reply(ExchangeChannel channel, Object message) throws RemotingException {
		return null;
	}
}
